package io.netty.example.mqtt.heartBeat;

import java.util.concurrent.TimeUnit;

/**
 * Description：
 *
 * @author : chenjie03@imdada.cn
 * Date: 2020/5/25
 * Time: 17:20
 */
public class MyTest {

    public static final String HOST = System.getProperty("host", "127.0.0.1");
    public static final int PORT = Integer.parseInt(System.getProperty("port", "1883"));
    private static final String CLIENT_ID = System.getProperty("clientId", "guestClient");
    private static final String USER_NAME = System.getProperty("userName", "guest");
    private static final String PASSWORD = System.getProperty("password", "guest");

    public static void main(String[] args) throws InterruptedException {
        MqttHeartBeatClient client = new MqttHeartBeatClient(HOST, PORT, CLIENT_ID, USER_NAME, PASSWORD);
        TimeUnit.SECONDS.sleep(10L);
        client.send("11111");
    }
}
